type google.golang.org/grpc.callInfo
43 uses
google.golang.org/grpc (current package)
rpc_util.go#L173: type callInfo struct {
rpc_util.go#L202: func defaultCallInfo() *callInfo {
rpc_util.go#L203: return &callInfo{
rpc_util.go#L237: before(*callInfo) error
rpc_util.go#L241: after(*callInfo, *csAttempt)
rpc_util.go#L249: func (EmptyCallOption) before(*callInfo) error { return nil }
rpc_util.go#L250: func (EmptyCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L283: func (o HeaderCallOption) before(*callInfo) error { return nil }
rpc_util.go#L284: func (o HeaderCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L305: func (o TrailerCallOption) before(*callInfo) error { return nil }
rpc_util.go#L306: func (o TrailerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L327: func (o PeerCallOption) before(*callInfo) error { return nil }
rpc_util.go#L328: func (o PeerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L363: func (o FailFastCallOption) before(c *callInfo) error {
rpc_util.go#L367: func (o FailFastCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L397: func (o OnFinishCallOption) before(c *callInfo) error {
rpc_util.go#L402: func (o OnFinishCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L422: func (o MaxRecvMsgSizeCallOption) before(c *callInfo) error {
rpc_util.go#L426: func (o MaxRecvMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L451: func (o AuthorityOverrideCallOption) before(c *callInfo) error {
rpc_util.go#L456: func (o AuthorityOverrideCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L476: func (o MaxSendMsgSizeCallOption) before(c *callInfo) error {
rpc_util.go#L480: func (o MaxSendMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L499: func (o PerRPCCredsCallOption) before(c *callInfo) error {
rpc_util.go#L503: func (o PerRPCCredsCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L527: func (o CompressorCallOption) before(c *callInfo) error {
rpc_util.go#L531: func (o CompressorCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L547: func (o acceptCompressorsCallOption) before(c *callInfo) error {
rpc_util.go#L556: func (acceptCompressorsCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L589: func (o ContentSubtypeCallOption) before(c *callInfo) error {
rpc_util.go#L593: func (o ContentSubtypeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L628: func (o ForceCodecCallOption) before(c *callInfo) error {
rpc_util.go#L632: func (o ForceCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L667: func (o ForceCodecV2CallOption) before(c *callInfo) error {
rpc_util.go#L672: func (o ForceCodecV2CallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L693: func (o CustomCodecCallOption) before(c *callInfo) error {
rpc_util.go#L697: func (o CustomCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L721: func (o MaxRetryRPCBufferSizeCallOption) before(c *callInfo) error {
rpc_util.go#L725: func (o MaxRetryRPCBufferSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L1160: func setCallInfoCodec(c *callInfo) error {
stream.go#L577: callInfo *callInfo
stream.go#L1289: c := &callInfo{}
stream.go#L1396: callInfo *callInfo